/*
package com.dawn.seckilldemo.rabbit;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

@Service
@Slf4j
public class MQReceiverDemo {
    @RabbitListener(queues = "queue")
    public void receive(Object msg){
        log.info("接收消息"+msg);
    }

    @RabbitListener(queues = "queue_fanout01")
    public void receive1(Object msg){
        log.info("qqqq1接收消息"+msg);
    }
//direct
    @RabbitListener(queues = "queue_direct01")
    public void queue_direct1(Object msg){
        log.info("queue_direct1111接收消息"+msg);
    }

    @RabbitListener(queues = "queue_direct02")
    public void queue_direct2(Object msg){
        log.info("queue_direct222接收消息"+msg);
    }
}
*/
